package com.itheima.bos.mq;

import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageListener;

import org.springframework.stereotype.Service;

import com.itheima.bos.utils.SmsUtils;

@Service("smsConsumer")
public class SmsConsumer implements MessageListener {

	@Override
	public void onMessage(Message message) {

		MapMessage mapMessage = (MapMessage) message;

		try {
			String result = SmsUtils.sendSmsByHTTP(mapMessage.getString("telephone"), mapMessage.getString("msg"));

			if(result.startsWith("000")){
				// 发送成功
				System.out.println("发送短信成功,手机号："
						+ mapMessage.getString("telephone") + "，验证码："
						+ mapMessage.getString("msg"));
			}else{
				// 发送失败
				throw new RuntimeException("短信发送失败, 信息码：" + result);
			}
			
		} catch (Exception e) {

			e.printStackTrace();
		}
	}

}
